package sos.entrega2013.mr1.noviembre;

import java.io.IOException;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.*;
import org.apache.hadoop.mapred.*;
import sos.entrega2013.mr1.noviembre.bo.facturacion.*;
import sos.entrega2013.mr1.noviembre.beans.*;

public class Facturacion {

	public static void main(String[] args) {
		try {
			JobConf conf = new JobConf(Facturacion.class);
			conf.setJobName("Facturacion");
			//define las salidas del map y del reduce
			conf.setOutputKeyClass(Text.class);
			conf.setOutputValueClass(CDR.class);
	
			conf.setMapperClass(FacturacionMap.class);
			//conf.setCombinerClass(FacturacionReduce.class);
			conf.setReducerClass(FacturacionReduce.class);
	
			conf.setInputFormat(TextInputFormat.class);
			conf.setOutputFormat(TextOutputFormat.class);
			FileInputFormat.setInputPaths(conf, new Path(args[0]));
			FileOutputFormat.setOutputPath(conf, new Path(args[1]));			
			JobClient.runJob(conf);
			
		} catch (IOException e) {
			e.printStackTrace();
		}		
	}
	

}
